package com.zy.explore.license.interfaces.assembler;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.zy.explore.license.application.service.SysEventLogService;
import com.zy.explore.license.domain.mybatis.entity.SysEventLog;
import com.zy.explore.license.infrastructure.util.DataBeanUtil;
import com.zy.explore.license.interfaces.frm.CommonIdFrm;
import com.zy.explore.license.interfaces.frm.SysEventLogFrm;
import com.zy.explore.license.interfaces.vo.PageVO;
import com.zy.explore.license.interfaces.vo.SysEventLogVO;
import com.google.common.collect.Lists;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageImpl;
import org.springframework.data.domain.PageRequest;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * 系统日志Assembler
 *
 * @author ChinaYin  主页:https://gitee.com/zy-explorej2ee 邮箱:zyexplorej2ee@sina.com
 * @date 2021年06月13日 12:13:50
 */
@Component
public class SysEventLogAssembler {

    /**
     * 注入service
     */
    @Resource
    private SysEventLogService service;

    /**
     * 新增数据
     *
     * @param frm 参数对象
     * @return 视图对象
     */
    public SysEventLogVO insert(SysEventLogFrm frm) {
        SysEventLog entity = convertFromFrm(frm);
        entity.setCreateTime(new Date());
        boolean res = service.save(entity);
        if (res) {
            return convertToVO(entity);
        }
        return null;
    }

    /**
     * 删除对象
     *
     * @param frm 参数对象
     * @return true:删除成功 false:删除失败
     */
    public boolean delete(CommonIdFrm frm) {
        return service.removeById(Long.parseLong(frm.getId()));
    }

    /**
     * 更新对象
     *
     * @param frm 待更新的Frm对象
     * @return 成功返回更新后的VO对象，失败返回null
     */
    public SysEventLogVO update(SysEventLogFrm frm) {
        SysEventLog entity = convertFromFrm(frm);
        boolean res = service.updateById(entity);
        if (res) {
            return convertToVO(entity);
        }
        return null;
    }

    /**
     * 根据ID查询数据
     *
     * @param frm 主键Frm对象
     * @return 成功返回对应ID的VO对象，失败返回null
     */
    public SysEventLogVO findById(CommonIdFrm frm) {
        SysEventLog entity = service.getById(Long.parseLong(frm.getId()));
        return convertToVO(entity);
    }

    /**
     * 根据条件查询数据集合
     *
     * @param frm 查询条件对象
     * @return 满足条件的数据集合
     */
    public List<SysEventLogVO> getList(SysEventLogFrm frm) {
        // 查询条件
        QueryWrapper<SysEventLog> wrapper = SysEventLog.getWrapper(frm);
        // 设置排序
        SysEventLog.setSortCriteria(frm.getSortFields(), wrapper, null, null);
        List<SysEventLog> list = SysEventLog.builder().build().findList(wrapper);
        if (!CollectionUtils.isEmpty(list)) {
            List<SysEventLogVO> retList = new ArrayList<>();
            list.forEach(x -> retList.add(convertToVO(x)));
            return retList;
        }
        return new ArrayList<>();
    }

    /**
     * 根据条件查询分页
     *
     * @param frm 查询条件
     * @return 满足条件的分页
     */
    public PageVO<SysEventLogVO> getPageInfo(SysEventLogFrm frm) {
        // 设置条件
        QueryWrapper<SysEventLog> wrapper = SysEventLog.getWrapper(frm);
        // 设置排序
        SysEventLog.setSortCriteria(frm.getSortFields(), wrapper, null, null);
        // 分页参数
        int pageNum = frm.getPageNum();
        int pageSize = frm.getPageSize();
        int total = 0;
        PageImpl<?> pageImpl = new PageImpl<>(Lists.newArrayList(), PageRequest.of(pageNum - 1, pageSize), total);
        // 查询分页
        Page<SysEventLog> pageInfo = SysEventLog.builder().build().findPageInfo(pageImpl, wrapper);
        // 转成PageVO
        PageRequest pageRequest = PageRequest.of(pageNum - 1, pageSize);
        List<SysEventLogVO> retList = new ArrayList<>();
        Page<SysEventLogVO> retPage = new PageImpl<>(retList, pageRequest, 0L);
        if (pageInfo == null || CollectionUtils.isEmpty(pageInfo.getContent())) {
            return new PageVO<>(retPage);
        }
        pageInfo.getContent().forEach(x -> retList.add(convertToVO(x)));
        retPage = new PageImpl<>(retList, pageRequest, pageInfo.getTotalElements());
        return new PageVO<>(retPage);
    }

    /**
     * 记录事件信息
     *
     * @param userId       用户ID
     * @param ip           ip地址
     * @param eventType    事件类型：1.老用户登录 2.新增 3.修改 4.删除 5.新用户登录
     * @param eventDesc    事件描述
     * @param eventContent 事件内容
     * @param eventResult  事件结果
     */
    @Async
    public void recordEvent(Integer userId, String ip, Integer eventType, String eventDesc, String eventContent, String eventResult) {
        service.recordEvent(userId, ip, eventType, eventDesc, eventContent, eventResult);
    }


    /**
     * frm转实体类
     *
     * @param frm 参数对象
     * @return 转换后的实体类对象
     */
    public static SysEventLog convertFromFrm(SysEventLogFrm frm) {
        return DataBeanUtil.copyOf(frm, SysEventLog.class, true);
    }

    /**
     * 实体类转VO
     *
     * @param entity 实体类
     * @return 转换后的对象
     */
    public static SysEventLogVO convertToVO(SysEventLog entity) {
       return entity == null ? null : DataBeanUtil.copyOf(entity, SysEventLogVO.class, true);
    }
}
